package com.csx.governance.traffic.mq.rocketmq.hook;

import org.apache.rocketmq.client.hook.FilterMessageContext;
import org.apache.rocketmq.client.hook.FilterMessageHook;

/**
 * 可以通过 user-property 中存储的key-value来对消息进行忧虑，调用 remove 即可忽略不关心的消息
 * @author cuisongxu
 * @date 2023/2/28 17:10
 */
public class TrafficFilterMessageHook implements FilterMessageHook {

    @Override
    public String hookName() {
        return null;
    }

    @Override
    public void filterMessage(FilterMessageContext context) {

    }

}
